package study.springboot.kafka.consumer.listener;

import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

@Slf4j
@Configuration
public class EchoListener {

    @KafkaListener(topics = "echo-topic", containerFactory = "user_KafkaListenerContainerFactory")
    public void onMessage(ConsumerRecords<String, String> records) {
        log.info("safdasdfasdf");
    }
}
